package mq

type Publisher struct {
	topic string
	name  string
	eb    *EventBus
}

func (p *Publisher) Publish(message *Message) {
	if p.eb == nil {
		return
	}
	p.eb.channel <- DefaultEvent{message}
}
